const {ChatModel} = require('../db/models')
module.exports = function (server) {
    const io = require('socket.io')(server, {cors: true})   // 配置了跨域
  
    console.log("ws服务器启动")
    // 监视客户端与服务器的连接
    io.on('connection', function (socket) {
      console.log('有一个客户端连接上了服务器')
  
      // 绑定监听, 接收客户端发送的消息
      socket.on('sendMsg', function ({from, to, content}) {
        console.log('服务器接收到客户端发送的消息', content)
        // 处理数据
        const chat_id = [from, to].sort().join('_')
        const create_time = Date.now()
        new ChatModel({from, to, content, create_time, chat_id}).save(function (error, chatMsg){
            // 服务器向所有客户端发送消息
            io.emit('receiveMsg', chatMsg)
        })
      })
    })
  }